package com.flink.cus.wdopers;


import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
import org.apache.flink.streaming.api.windowing.time.Time;

public class stockTsWmarkPerdAssigner2 extends BoundedOutOfOrdernessTimestampExtractor<Tuple3<Long, Float, Long>>{

    public stockTsWmarkPerdAssigner2(Time maxOutOfOrderness) {
        super(maxOutOfOrderness);
    }

    @Override
    public long extractTimestamp(Tuple3<Long, Float, Long> event) {        
        return event.f0;
    }


    
}
